package com.hyperfix.washer.listener;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * @author JiangChunYu
 * 2024/3/23
 */
@Component
public class DWListener {
    @Resource
    private MessageTransfer messageTransfer;

    @KafkaListener(topics = "DW", groupId = "DW")
    public void onMessage(byte[] data) {
        messageTransfer.transmitMessage(data);
    }
}
